/**
 * Copyright ©2003~2019年5月23日 szkingdom
 * @author raohj
 * @date 2019年5月23日
 * @file RJMSSender.java
 * @comment : please input your comment to this file
 * @version : input version
 * @modify:
 * 		1、 2019年5月23日 由 raohj 新建文件
 */
package com.ccnu.demojava.mq.jms.p2p;

import javax.jms.*;
import javax.naming.InitialContext;
/**
 * @author raohj
 * @date 2019年5月23日
 * @version 
 * @comment to add your comment
 */
public class RJMSSender {
    public static void main(String[] args) throws Exception
    {
       // get the initial context
       InitialContext context = new InitialContext();
                                                              
       // lookup the queue object
       Queue queue = (Queue) context.lookup("queue/queue0");
                                                                          
       // lookup the queue connection factory
       QueueConnectionFactory conFactory = (QueueConnectionFactory) context.lookup ("queue/connectionFactory");
                                                                          
       // create a queue connection
       QueueConnection queConn = conFactory.createQueueConnection();
                                                                          
       // create a queue session
       QueueSession queSession = queConn.createQueueSession(false, Session.DUPS_OK_ACKNOWLEDGE);
                                                                          
       // create a queue sender
       QueueSender queSender = queSession.createSender(queue);
       queSender.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
                                                                          
       // create a simple message to say "Hello World"
       TextMessage message = queSession.createTextMessage("Hello World");
                                                    
       // send the message
       queSender.send(message);
                                                                         
       // print what we did
       System.out.println("Message Sent: " + message.getText());
                                                                          
       // close the queue connection
       queConn.close();
    }
}
